package com.Reactor3参考文档.service;

import org.reactivestreams.Publisher;

import reactor.core.publisher.Flux;

import com.Reactor3参考文档.domain.Favorite;

public class SuggestionService {

	public Publisher<? extends Favorite> getSuggestions() {
		return Flux.just(new Favorite(6, "人工智能"),
				new Favorite(7, "java编程思想"),
				new Favorite(8, "sofarpc"),
				new Favorite(9, "大数据"),
				new Favorite(10, "算法导论"));
	}

}
